﻿using System;
using System.Threading;
using JT808.Gateway.Abstractions;

namespace JT808.Gateway.Internal
{
    class JT808NotifyConsumer_Empty : IJT808NotifyConsumer
    {
        public CancellationTokenSource Cts => new CancellationTokenSource();

        public string TopicName { get; }

        public void Dispose()
        {
        }

        public void OnMessage(Action<(string notifyKey, byte[] param)> callback)
        {

        }

        public void Subscribe()
        {

        }

        public void Unsubscribe()
        {

        }
    }
}
